HiSEN

MongoDB - 简单操作 - CRUD - JAVA

发表于 | 分类于

之前我记得写过简单的测试类，但是忘了，现在重新写一个

顺便用博客记录下，mongodb系列应该会有几篇记录

本篇具体代码：SampleMongoTestNo1.java

1、环境介绍

mongodb安装教程：点击查看

1
2
3
4
5
6
7
8
DataBase：MongoDB V 3.2
Driver　：3.4.1
maven：
    <dependency>
      <groupId>org.mongodb</groupId>
      <artifactId>mongo-java-driver</artifactId>
      <version>3.4.1</version>
    </dependency>

２、初始化连接

1
2
3
4
5
6
7
8
9
10
11
12
13
private Mongo mg = null;
private DB db;
private DBCollection dbCollection;

@Before
public void initDB(){
  //建立连接
  mg = new MongoClient("127.0.0.1",27017);
  //获取要操作的数据库实例，没有会创建
  db = mg.getDB("hisen");
  //获取要操作的集合实例，没有会创建
  dbCollection = db.getCollection("emp");
}

3、关闭连接

1
2
3
4
5
6
7
8
9
@After
  public void destoryDB(){
    if (mg == null) {
      mg.close();
      mg=null;
      db=null;
      dbCollection=null;
    }
  }

4、CRUD操作

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
/**
   * 插入数据
   */
  @Test
  public void testCreate(){
    DBObject obj = null;
    for (int i = 1; i <= 10; i++) {
      obj = new BasicDBObject("_id",i).append("name","hisen"+i).append("age",i*5);
      dbCollection.save(obj);
    }
  }

  /**
   * 查询所有
   */
  @Test
  public void testReadAll(){
    DBCursor dbCursor = dbCollection.find();
    while (dbCursor.hasNext()){
      System.out.println(dbCursor.next());
    }
  }

  /**
   * 修改记录
   */
  @Test
  public void testUpdate(){
    BasicDBObject condition = new BasicDBObject("_id",10);
    BasicDBObject res = new BasicDBObject("name", "hisen10_new");
    //若没有此语句，直接调用下面的语句，返回结果{ "_id" : 10 , "name" : "hisen10_new"}
    BasicDBObject res2 = new BasicDBObject("$set", res);
    dbCollection.update(condition,res2);
    System.out.println(dbCollection.findOne(new BasicDBObject("_id",10)));
  }

  /**
   * 删除记录
   */
  @Test
  public void testDelete(){
    dbCollection.remove(new BasicDBObject("_id",10));
    testReadAll();
  }

  /**
   * 根据主键查询
   */
  @Test
  public void testReadOneWithId(){
    DBObject object = dbCollection.findOne(new BasicDBObject("_id",1));
    System.out.println(object);
  }

  /**
   * 模糊查询 - 使用正则
   */
  @Test
  public void testReadPuzzy(){
    Pattern pattern = Pattern.compile("^hisen1");
    BasicDBObject basicDBObject = new BasicDBObject("name",pattern);
    DBCursor dbCursor = dbCollection.find(basicDBObject);
    while (dbCursor.hasNext()){
      System.out.println(dbCursor.next());
    }
  }

  /**
   * 清空集合
   */
  @Test
  public void testDrop(){
    dbCollection.drop();
    testReadAll();
  }